package cn.aiyuan.pojo;

import lombok.Data;

import javax.websocket.Session;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * <websocket信息对象>
 * <用于存储socket连接信息>
 * @author wzh
 * @version 2018-07-08 18:49
 * @see [相关类/方法] (可选)
 **/
@Data
public class WebSocket {

    private Long id;

    /**
     * 连接session对象
     */
    private Session session;

    /**
     * 连接错误次数
     */
    private AtomicInteger errorLinkCount = new AtomicInteger(0);

    public int getErrorLinkCount() {
        // 线程安全,以原子方式将当前值加1，注意：这里返回的是自增前的值
        return errorLinkCount.getAndIncrement();
    }

    public void cleanErrorNum(){
        // 清空计数
        errorLinkCount = new AtomicInteger(0);
    }

}
